# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor

jms_dm_dependent_dwd_tab_barscan_collect_base_hi = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dm_dependent_dwd_tab_barscan_collect_base_hi",
    filepath='/dw/hive/jms_dwd.db/external/dwd_tab_barscan_collect_base_hi/dt={{ execution_date | cst_hour }}',
    execution_timeout = timedelta(minutes=60),
    email=['wangmenglei@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)